package jdbc;

import jdbc.util.JdbcUtil;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

/**
 * 增删改操作
 */
public class jdbcTest03 {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement ps =null;
        try {
            //获取连接
            conn= JdbcUtil.getconnection();
            //获取预编译的数据库操作对象
            /**
             * 增操作
             */
          String sql="insert into staff (pno,name,award,reason) values (?,?,?,?)";
            ps= conn.prepareStatement(sql);
            ps.setInt(1,60);
            ps.setString(2,"王二");
            ps.setInt(3,200);
            ps.setString(4,"加班");

            /**
             * 改操作
             */
            /*String sql="update dept set dname=?,loc=? where deptno=? ";
            ps= conn.prepareStatement(sql);
            ps.setString(1,"研发一部");
            ps.setString(2,"北京");
            ps.setInt(3,60);*/
            /**
             * 删操作
             */
          /*  String sql="delete from dept where deptno=?";
            ps= conn.prepareStatement(sql);
            ps.setInt(1,60);*/

            //执行sql
            int count= ps.executeUpdate();
            System.out.println(count);
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            JdbcUtil.colse(conn,ps,null);
        }
    }
}
